package com.opengate.base.stream;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * @author 曳戈泰尔
 * @version 1.0
 * @description 定义一个输出通道，用于向消息中间件发送消息
 * @date 2023/4/26 5:46 PM
 */
public interface RepOutput {

    /** 输出通道的名称 */
    String OUTPUT = "repOutput";

    /**
     * @return 返回一个可发送消息的消息通道
     */
    @Output(RepOutput.OUTPUT)
    MessageChannel output();
}
